package m1;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.io.IOException;

public class Producer {
    public static void main(String[] args) throws Exception {
        // 建立连接
        ConnectionFactory f = new ConnectionFactory();
        f.setHost("192.168.64.140"); //www.wht6.cn
        f.setPort(5672);
        f.setUsername("admin");
        f.setPassword("admin");

        Connection conn = f.newConnection(); //网络连接
        Channel c = conn.createChannel();    //通信通道

        // 定义队列 helloworld，服务器不存在这个队列会新建队列，反之使用已存在的队列
        // 在这里告诉服务器，让服务器准备好这个队列
        c.queueDeclare(
                "helloworld",
                false,          // 是否是持久队列
                false,         // 是否是排他队列（独占）
                false,       // 是否自动删除
                null);       // 其他的属性配置

        // 发送消息
        c.basicPublish(
                "",                 // 第三种模式才会用到
                "helloworld",
                null,                  // 针对发送的这条消息，可以添加其他属性设置
                "Hello world!".getBytes());
        System.out.println("消息已发送");
    }
}
